privateGPT MCP Server

package main import ( "bytes" "encoding/json" "errors" "flag" "fmt" "io" "net" "os" ) type ListSourcesPayload struct { Command string `json:"command"` Token string `json:"token"` Attributes map[string]interface{} `json:"attributes"` } func sendListSourcesRequest(serverIP string, serverPort int, token, groupName string) (string, error) { // Prepare the request payload payload := ListSourcesPayload{ Command: "list_sources", Token: token, Attributes: map[string]interface{}{ "groupName": groupName, }, } // Convert the payload to JSON payloadJSON, err := json.Marshal(payload) if err != nil { return "", err } // Create a connection to the server conn, err := net.Dial("tcp", fmt.Sprintf("%s:%d", serverIP, serverPort)) if err != nil { return "", err } defer conn.Close() // Send the request _, err = conn.Write(payloadJSON) if err != nil { return "", err } // Receive the response var responseBuffer bytes.Buffer buf := make([]byte, 4096) for { n, err := conn.Read(buf) if err != nil { if errors.Is(err, io.EOF) { break } return "", err } responseBuffer.Write(buf[:n]) if n < 4096 { break } } return responseBuffer.String(), nil } func main() { serverIP := flag.String("server-ip", "", "IP address of the MCP server") serverPort := flag.Int("server-port", 0, "Port number of the MCP server") token := flag.String("token", "", "Authentication token") groupName := flag.String("group-name", "", "Name of the group to list sources from") flag.Parse() if *serverIP == "" || *serverPort == 0 || *token == "" || *groupName == "" { fmt.Println("❌ ERROR: All flags are required.") flag.Usage() os.Exit(1) } // Send the request to list sources fmt.Println("📤 Sending request to list sources...") response, err := sendListSourcesRequest(*serverIP, *serverPort, *token, *groupName) if err != nil { fmt.Printf("❌ ERROR: %v\n", err) os.Exit(1) } fmt.Println("✔️ Response from server:") fmt.Println(response) }